package com.ynet.eq.mqtt.consumer;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author 胡超雄
 * @date 2021/6/30 16:45
 * @desc 消息处理 接口 使用spi 机制不同厂商实现不同
 */
public interface MessageArrived {

    /**
     * 处理消息
     */
    Boolean processMessage(String s, MqttMessage message);


}
